package com.central.user.mq

import org.springframework.cloud.stream.annotation.EnableBinding
import org.springframework.cloud.stream.annotation.Input
import org.springframework.messaging.SubscribableChannel

/**
 * @author  fly
 * @date  2021/6/2 16:00
 * @version 1.0
 */

const val integralInput = "integral_service_input"

@EnableBinding(UserSink::class)
open class UserMqConfig

interface UserSink{

    @Input(integralInput)
    fun integralInput(): SubscribableChannel
}

